package com.kafka.utils;

import com.common.Common;

/**
 * @author xin.ding
 * @date 2019/12/7 15:32
 */
public class Test {

    public static void main(String[] args) {
        String[] s = new String[]{"{\"userName\":\"赵四31\",\"pwd\":\"lisi\",\"age\":13}",
                "{\"userName\":\"赵四41\",\"pwd\":\"lisi\",\"age\":14}",
                "{\"userName\":\"赵四51\",\"pwd\":\"lisi\",\"age\":15}"};

        Producer.sendMessage(Common.KAFKA_TOPIC, s);
        Consumer.consumer(Common.KAFKA_TOPIC);
    }
}
